package org.lzfto.flink.demo.config.mqtt;

import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.MessagingException;

public class CustMqttInMessageHandler implements MessageHandler {

	@Override
	public void handleMessage(Message<?> message) throws MessagingException {
		Object msg=message.getPayload();	
		System.out.println(msg==null?"空消息":msg.toString());

	}

}
